package com.joven.shelltest.service.impl;

import com.joven.shelltest.dto.MqReq;
import com.joven.shelltest.dto.MqRsp;
import com.joven.shelltest.service.MessageHandler;
import org.springframework.stereotype.Service;

/**
 * @Author wzj
 * @Date 2023-09-14 16:52
 **/
@Service("mqDealMessage")
public class MqDealMessage implements MessageHandler<MqRsp, MqReq> {

    @Override
    public MqRsp process(MqReq requestObj) {
        MqRsp rsp = new MqRsp();
        rsp.setMsg(requestObj.getName());
        rsp.setResult(requestObj.getAddr());
        return rsp;
    }
}
